﻿//
//
// 版权所有 (c) 2021-2023 JR  
//
// 特此免费授予获得本软件的任何人以处理本软件的权利，但须遵守以下条件：在所有副本或重要部分的软件中必须包括上述版权声明和本许可声明。
//
// 软件按“原样”提供，不提供任何形式的明示或暗示的保证，包括但不限于对适销性、适用性和非侵权的保证。
// 在任何情况下，作者或版权持有人均不对任何索赔、损害或其他责任负责，无论是因合同、侵权或其他方式引起的，与软件或其使用或其他交易有关。

using Microsoft.AspNetCore.SignalR;
using Microsoft.CodeAnalysis.CSharp.Syntax;
using NewLife.Reflection;
using SqlSugar.Extensions;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace EMC.VISITOR.Core;
public class MyEventHandlerMonitor : IEventHandlerMonitor
{
    private readonly IServiceScopeFactory _serviceScopeFactory;
    public MyEventHandlerMonitor(IServiceScopeFactory scopeFactory)
    {
        _serviceScopeFactory = scopeFactory;
    }
    /// <summary>
    /// 执行之前
    /// </summary>
    /// <param name="context"></param>
    /// <returns></returns>
    public async Task OnExecutingAsync(EventHandlerExecutingContext context)
    {
        var str = JSON.Serialize(context.Source);
        string eventId = context.Source.EventId;
        using var scope = _serviceScopeFactory.CreateScope();
        var _rep = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<SysMqPublish>>();
        var rabbitMqOptions = App.GetOptions<RabbitMqOptions>();
        var pub = new SysMqPublish
        {
            Node = string.Empty,
            Connection = string.Empty,
            VirtualHost = string.Empty,
            Channel = string.Empty,
            Exchange = string.Empty,
            User = rabbitMqOptions.Name,
            RoutingKeys = rabbitMqOptions.Author,
            RoutedQueues = rabbitMqOptions.Author,
            HandlerResult = true,
            EventId = context.Source.EventId,
            Payload = JSON.Serialize(context.Source.Payload),
            CreateTime = context.Source.CreatedTime,
            ASoleId = context.Source.GetValue(nameof(SysMqPublish.ASoleId)).ObjToString()
        };
        await _rep.InsertAsync(pub);
    }

    /// <summary>
    /// 执行之后--如果没有订阅
    /// </summary>
    /// <param name="context"></param>
    /// <returns></returns>
    public async Task OnExecutedAsync(EventHandlerExecutedContext context)
    {
        var str = JSON.Serialize(context.Source);
        string eventId = context.Source.EventId;
        using var scope = _serviceScopeFactory.CreateScope();
        var _rep = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<SysMqSubscriber>>();
        var rabbitMqOptions = App.GetOptions<RabbitMqOptions>();
        var sub = new SysMqSubscriber
        {
            Node = string.Empty,
            Connection = string.Empty,
            VirtualHost = string.Empty,
            Channel = string.Empty,
            Exchange = string.Empty,
            User = rabbitMqOptions.Name,
            RoutingKeys = rabbitMqOptions.Author,
            RoutedQueues = rabbitMqOptions.Author,
            HandlerResult = true,
            EventId = context.Source.EventId,
            Payload = JSON.Serialize(context.Source.Payload),
            CreateTime = context.Source.CreatedTime,
            ASoleId = context.Source.GetValue(nameof(SysMqPublish.ASoleId)).ObjToString()
        };
        if (context.Exception != null)
        {
            sub.HandlerResult = false;
            sub.ExceptionMessage = context.Exception.ToString();
        }
        try
        {
            await _rep.InsertAsync(sub);
        }
        catch (Exception ex)
        {
            sub.HandlerResult = false;
            sub.ExceptionMessage = ex.ToString();
            await _rep.InsertAsync(sub);
        }
    }
}